<?php
//设置php脚本执行时间
set_time_limit (0);
//设置socket连接超时时间
ini_set ('default_socket_timeout', -1);
//声明测试频道名称
$channelName = "testPubSub";
$redis = new \Redis();
//建立一个长链接
$redis->connect ('127.0.0.1', 6379);
echo "订阅者已启动\n\r\n\r";
//阻塞获取消息
$redis->subscribe([$channelName],function ($redis1,$chan,$msg){
    //模拟数据处理耗时
    sleep(3);
    //模拟写入数据库
    file_put_contents (__DIR__.'/jyy.log',$chan.':'.$msg."\n\r\n\r",FILE_APPEND);
});
